package com.datang.pet.api.talkController;

import com.datang.pet.vo.AddTalkRequest;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

@Component
public class MergeProducer {
    @Autowired
    private JmsMessagingTemplate jmsTemplate;

    public void sendMessage(ActiveMQQueue destination, AddTalkRequest addTalkRequest) {
         jmsTemplate.convertAndSend(destination, addTalkRequest);
    }
}
